Execute grpcCalls on Application executor service#1506
Merged
Conversation
8d1c9f6 to
457a432
Compare
457a432 to
3b59875
Compare
Contributor
There was a problem hiding this comment.
Pull request overview
This PR updates the gRPC executor implementation so gRPC calls (including streaming) run on the application-provided executor service, aligning async execution and callback handling with the workflow runtime’s configured thread pool.
Changes:
- Route gRPC
ClientCallexecution/callbacks throughWorkflowApplication.executorService()viaCallOptions.withExecutor(...). - Offload client/bidi streaming request message production to the application executor instead of running inline on the caller thread.
Reviewed changes
Copilot reviewed 2 out of 2 changed files in this pull request and generated 1 comment.
| File | Description |
|---|---|
| impl/grpc/src/main/java/io/serverlessworkflow/impl/executors/grpc/ProtobufMessageUtils.java | Moves streaming request writes onto the application executor; needs stricter error/rejection handling to avoid hanging futures and invalid stream termination. |
| impl/grpc/src/main/java/io/serverlessworkflow/impl/executors/grpc/GrpcExecutor.java | Configures gRPC calls to use the application executor via CallOptions.withExecutor(...) and updates streaming call sites accordingly. |
💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.
3b59875 to
1a034a8
Compare
1a034a8 to
37f5f45
Compare
37f5f45 to
f514e15
Compare
f514e15 to
743365c
Compare
743365c to
f37ea5c
Compare
f37ea5c to
c6f7801
Compare
c6f7801 to
9ce831b
Compare
mcruzdev
approved these changes
Jun 29, 2026
9ce831b to
54def0c
Compare
54def0c to
6607242
Compare
6607242 to
8502633
Compare
16d66cb to
638e5ac
Compare
638e5ac to
715a3b1
Compare
715a3b1 to
9a65dac
Compare
9a65dac to
c5667f8
Compare
c5667f8 to
d41cbec
Compare
d41cbec to
95dcc10
Compare
95dcc10 to
5d6d5ac
Compare
Signed-off-by: fjtirado <ftirados@ibm.com>
5d6d5ac to
727cb2e
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Convert grpc calls in real async calls over the executor service provided by the application